package com.howso.cloud.kafka.dto;

import lombok.Data;


@Data
public class KafkaConfigDTO {
    /**
     * 消费者的自定义名称,用于获取指定的Listener<p>
     * 默认为实现类的名称
     */
    private String name;
    /**
     * kafka 服务地址
     */
    private String bootstrapServers;
    /**
     * 消费者的groupId
     */
    private String groupId;

    /**
     * 监听的队列
     */
    private String[] topics;
}
